26c42b9802ac88d2710071ff30fae2575b84c0ed,runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowClient.java,DataflowClient,createJob,#Job#,57
Before Change
*/
public Job createJob(@Nonnull Job job) throws IOException {
checkNotNull(job, "job");
Jobs.Create jobsCreate = dataflow.projects().jobs().create(projectId, job);
return jobsCreate.execute();
}
After Change
*/
public Job createJob(@Nonnull Job job) throws IOException {
checkNotNull(job, "job");
Jobs.Create jobsCreate = dataflow.projects().locations().jobs()
.create(options.getProject(), options.getRegion(), job);
return jobsCreate.execute();
}